//package com.ycrlkj.android.modulespublic.common.net.transformer;
//
//import android.util.Log;
//import androidx.annotation.NonNull;
//import com.ycrlkj.android.modulespublic.common.net.response.MResponse;
//import io.reactivex.Observable;
//import io.reactivex.ObservableSource;
//import io.reactivex.ObservableTransformer;
//import io.reactivex.functions.Function;
//
////数据转换集成在公共转换器内, 不单独使用, 此处注释
//public class DataTransformer<T> implements ObservableTransformer<MResponse<T>, T> {
//
//    @Override
//    public ObservableSource<T> apply(Observable<MResponse<T>> upstream) {
//        return upstream
//                //json转换
//                .flatMap(new Function<MResponse<T>, ObservableSource<T>>() {
//                    @Override
//                    public ObservableSource<T> apply(@NonNull MResponse<T> response) throws Exception {
//
//                        Log.e("ming", "请求解析中");
//
//                        return new ResponseDataHandler<T>(response).doWith();
//
//                    }
//                });
//    }
//}
